package trace

import (
	streamCtx "gluenet/internal/glue-datasyncer/context"
)

func Traces(c *streamCtx.StreamContext) {
	//c.Logger.Debugf("receive trace")

	if err := c.DB.Es.WriteSpan(c.RpcContext.Data.Data); err != nil {
		c.Logger.Errorf("insert trace %v", err)
	} else {
		//c.Logger.Debugf("insert trace succeed")
	}
}
